package com.dog.framework.mqtt;

/**
 * @author liuxk
 * @since 2023/11/21
 */
public class MqttConstant {

    /**
     * 不带群组的共享订阅Topic前缀 $queue/{topic}
     */
    public static final String SHARED_SUBSCRIBE_PREFIX="$queue/";

    /**
     * 系统主题前缀
     */
    public static final String SYS_TOPIC_PREFIX="$SYS/brokers/";
    /**
     * 客户端上线下事件系统Topic：$SYS/brokers/${node}/clients/
     */
    public static final String SYS_TOPIC_CLIENT="$SYS/brokers/+/clients/#";

    /**
     * 客户端上线事件
     */
    public static String SYS_TOPIC_CLIENTS_CONNECTED_EVENT = "connected";
    /**
     * 客户端下线事件
     */
    public static String SYS_TOPIC_CLIENTS_DISCONNECTED_EVENT = "disconnected";

    /**
     * 发布的bean名称
     */
    public static final String CHANNEL_NAME_OUT = "mqttOutboundChannel";
}
